blob: 753c1b28e5b6842a73755a987d7cce63b57ce2a4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
"use server"
/**
* 사적이고 우회적인 요청사항...
-- readonly 사용자 생성 (비밀번호 설정)
CREATE USER readonly WITH PASSWORD 'tempReadOnly_123';
-- evcp 데이터베이스에 연결할 수 있는 권한 부여
GRANT CONNECT ON DATABASE evcp TO readonly;
-- 조회할 스키마 사용 권한 부여
GRANT USAGE ON SCHEMA public TO readonly;
GRANT USAGE ON SCHEMA soap TO readonly;
GRANT USAGE ON SCHEMA nonsap TO readonly;
GRANT USAGE ON SCHEMA mdg TO readonly;
-- 기존 모든 테이블에 대한 SELECT 권한 부여
GRANT SELECT ON ALL TABLES IN SCHEMA public TO readonly;
GRANT SELECT ON ALL TABLES IN SCHEMA soap TO readonly;
GRANT SELECT ON ALL TABLES IN SCHEMA nonsap TO readonly;
GRANT SELECT ON ALL TABLES IN SCHEMA mdg TO readonly;
*/
import { Pool } from "pg"
export interface QueryResultState {
columns: string[]
// eslint-disable-next-line @typescript-eslint/no-explicit-any
rows: Record<string, any>[]
error?: string
}
export async function executeSqlAction(
prevState: QueryResultState,
formData: FormData
): Promise<QueryResultState> {
const query = (formData.get("query") as string | null) ?? ""
if (!query.trim()) {
return { ...prevState, error: "쿼리를 입력해주세요." }
}
try {
const connectionString = process.env.READONLY_DB_URL
if (!connectionString) {
return { ...prevState, error: "READONLY_DB_URL 환경변수가 설정되지 않았습니다." }
}
const pool = new Pool({ connectionString })
const result = await pool.query(query)
await pool.end()
return {
columns: result.fields.map((f) => f.name),
// eslint-disable-next-line @typescript-eslint/no-explicit-any
rows: result.rows as Record<string, any>[],
}
} catch (err) {
return { ...prevState, error: (err as Error).message }
}
}
|
